//package com.int_tech.utils;
//
//import com.int_tech.mession.dao.MessionDao;
//import com.int_tech.messionLog.dao.MessionLogDao;
//import com.int_tech.messionLog.entity.MessionLog;
//import org.springframework.beans.factory.annotation.Autowired;
//
//import java.io.IOException;
//import java.io.InputStream;
//import java.io.OutputStream;
//import java.net.Socket;
//import java.util.Date;
///**
// * Created by Administrator on 2017/9/21.
// */
//public class ThreadServerSocket  implements Runnable{
//
//    private Socket server;
//
//    private int BUFFER_SIZE = 1024;
//
//    public ThreadServerSocket(Socket i) {
//        // TODO Auto-generated constructor stub
//        server = i;
//    }
//    //接收处理牛总发来的数据
//    public MessionLog saveClient(String date)
//    {
//        //处理数据，存储
//        MessionLog messionLog = MessageHelp.messionHelp(date);
//        messionLog.setCreateTime(new Date());
//        messionLog.setUpdateTime(new Date());
//        return messionLog;
//    }
//
//    @Override
//    public void run() {
//        // TODO Auto-generated method stub
//        try {
//            InputStream in = server.getInputStream();
//            OutputStream out = server.getOutputStream();
//            byte[] recData = null;
//            while(true) {
//                recData = new byte[BUFFER_SIZE];
//                int r = in.read(recData);
//                //int r = in.read(recData);
//                if(r>-1) {
//                    String data = new String(recData);
//                    if(data.trim().equals("over")) {
//                        server.close();
//                        break;
//                    }
//                    System.out.println("读取到客户端发送的来数据："+data);
//
//                    this.saveClient(data);
//
//                    out.write("这是服务端发给客户端的数据：".getBytes());
//                    out.write(recData);
//                }else {
//                    System.out.println("数据读取完毕！");
//                    server.close();
//                    break;
//                    //ss.close();
//                }
//            }
//        } catch (IOException e) {
//            // TODO Auto-generated catch block
//            e.printStackTrace();
//        } finally {
//            try {
//                server.close();
//            } catch (IOException e) {
//                // TODO Auto-generated catch block
//                e.printStackTrace();
//            }
//        }
//
//    }
//
//}
